06b575093123e3642ed0972a60f169f5118fc27a,modules/tasks/tasks/src/main/java/org/motechproject/tasks/service/impl/TaskTriggerHandler.java,TaskTriggerHandler,handleRetry,#MotechEvent#,154
Before Change
@Override
@Transactional
public void handleRetry(MotechEvent event) {
if (!getIsHandled()) {
setIsHandled(true);
LOGGER.info("Handling the motech event with subject: {} for task retry", event.getSubject());
Map<String, Object> eventParams = event.getParameters();
Map<String, Object> eventMetadata = event.getMetadata();
Task task = taskService.getTask((Long) eventMetadata.get(TASK_ID));
if (task == null || !task.isEnabled()) {
taskRetryHandler.unscheduleTaskRetry((String) eventMetadata.get(JOB_SUBJECT));
} else {
handleTask(task, eventParams, true);
}
setIsHandled(false);
After Change
if (!isTaskHandled(task)) {
addTaskHandled(task);
handleTask(task, eventParams, true);
deleteTaskHandled(task);
}